<?php
require_once(MODULESPATH . "core/d.object.class.php");
require_once(MODULESPATH . "finance/dataaccess/d.finance.inc.php");

/**
 * 财经系统数据层投资数据类。
 */
class DInvestment extends DObject implements IDInvestment{
    /*- IDInvestment 接口实现 START -*/
    /*- IInjectEnable 接口实现 START -*/
    /**
     * 设置属性值。
     */
    public function __set($prop, $val){
        $this->$prop = $val;
    }
    /*- IInjectEnable 接口实现 END -*/
    
    /**
     * 添加证券交易数据。
     * @param String $symbol 证券代码。
     * @param Int $combinationId 投资组合ID。
     * @param Int $uid 用户ID。
     * @param Int $type 交易类型。
     * @param Int $date 交易日期。
     * @param Int $quantity 证券数量。
     * @param Int $cost 证券总成本。
     * @param String $note 交易手记。
     */
    public function addInvestment($symbol, $combinationId, $uid, $type, $date, $quantity, $cost, $note){
        $result = 0;
        $sql = "insert into finance_stock_investments (stock_symbol, combination_id, owner_id, investment_type, investment_date, investment_quantity, investment_cost, investment_note, update_time, create_time) values ('$symbol', $combinationId, $uid, $type, $date, $quantity, $cost, '$note'," . time() . "," . time() . ");";
        try{
            $this->dao->runSql($sql);
            $result = 1;
        }catch(Exception $ex){
        }
        return $result;
    }
    
    /*- IAdjustUserData 接口实现 START -*/
    /**
     * 更换数据的用户ID。
     * @param Int $oldId 用户旧ID。
     * @param Int $newId 用户新ID。
     * @return 是否操作成功。
     */
    public function replaceByUid($oldId, $newId){
        $result = 0;
        $sql = "update finance_stock_investments set owner_id = $newId WHERE  `owner_id` =  $oldId;";
        try{
            $this->dao->runSql($sql);
            $result = 1;
        }catch(Exception $ex){
        }
        return  $result;
    }
    
    /**
     * 根据用户ID删除数据。
     * @param Int $uid 用户ID。
     * @return 是否操作成功。
     */
    public function deleteByUid($uid){
        $result = 0;
        $sql = "delete from finance_stock_investments WHERE `owner_id` =  $uid;";
        try{
            $this->dao->runSql($sql);
            $result = 1;
        }catch(Exception $ex){
        }
        return  $result;
    }
    /*- IAdjustUserData 接口实现 END -*/
    /*- IDInvestment 接口实现 END -*/
}
?>
